package com.eii.eiimq.service;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;

/**
 * @Auther: eii
 * @Date: 2020/7/11 14:00
 * @Description: 消费msg的业务类
 */
@Service
public class RecvmsgTaskService {

    Logger logger = LoggerFactory.getLogger(RecvmsgTaskService.class);

    public boolean processMsg(String msg){
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        //业务处理，消费msg
        logger.info("消费者 处理消息:{}", msg);

        //根据业务处理的结果 返回结果
        return true;
    }
}
